package com.leinao.mapper;

import com.leinao.domain.DeviceData;
import com.leinao.domain.param.DeviceDataQueryParam;
import org.apache.ibatis.annotations.Param;

import java.util.Date;
import java.util.List;

/**
 * description
 *
 * @author zhong.wang
 * @date 2025/1/13
 */
public interface TdengineMapper {
    /**
     * 获取最后一次同步时间
     * @return
     */
    Date getLastSyncTime();

    /**
     * 更新同步时间
     * @param ts
     */
    void updateSyncTime(@Param("ts") Date ts);

    /**
     * 创建表
     */
    void createTable(@Param("tableName") String tableName);

    void deleteTable(@Param("tableName") String tableName);

    /**
     * 批量插入数据
     */
    void insertDeviceData(@Param("list") List<DeviceData> list);

    List<DeviceData> getListByTs(@Param("param")DeviceDataQueryParam queryParam);


}
